package taskmanager

//
////SaveTaskSteps 存储step到数据库
//func (m *TaskManager) SaveTaskSteps(ctx context.Context, steps model.TaskSteps) codes.Code {
//	data := make([]interface{}, 0)
//	for _, s := range steps {
//		data = append(data, s)
//	}
//	if _, err := m.db.Collection(ctx, model.TaskStep{}.TableName()).InsertMany(ctx, data); err != nil {
//		log.Errorf("add task steps to db error:%s", err.Error())
//		return codes.ErrDatabase.Wrap(err)
//	}
//	return nil
//}
//
////UpdateTaskStepStatus 更新step状态
//func (m *TaskManager) UpdateTaskStepStatus(ctx context.Context, id string, status model.TaskStepStatus) codes.Code {
//	if _, err := m.db.Collection(ctx, model.TaskStep{}.TableName()).UpdateOne(ctx, bson.M{"id": id}, bson.M{"$set": bson.M{"status": status}}); err != nil {
//		log.Errorf("update task step error:%s", err.Error())
//		return codes.ErrDatabase.Wrap(err)
//	}
//	return nil
//}
//
//func (m *TaskManager) GetAllStatusTaskSteps(ctx context.Context, status model.TaskStepStatus) ([]*model.TaskStep, codes.Code) {
//	steps := make([]*model.TaskStep, 0)
//	res, err := m.db.Collection(ctx, model.TaskStep{}.TableName()).Find(ctx, bson.M{"status": status})
//	if err != nil {
//		log.Errorf("get all waiting task steps from db error:%s", err.Error())
//		return nil, codes.ErrDatabase.Wrap(err)
//	}
//	if errBind := res.All(ctx, &steps); errBind != nil {
//		log.Errorf("bind all waiting task steps from db error:%s", err.Error())
//		return nil, codes.ErrDatabase.Wrap(err)
//	}
//	return steps, nil
//}
